package com.sugon.ohdfs.integration.flink.service;

import com.sugon.ohdfs.integration.flink.domain.TestItem;
import lombok.extern.slf4j.Slf4j;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;

@Slf4j
public class ConsoleSink implements SinkFunction<TestItem> {

    @Override
    public void invoke(TestItem value, Context context) throws Exception {
        if(log.isInfoEnabled()){
            log.info(value.toString());
        }
    }
}
